package com.yanfan.mqttclient;

import com.yanfan.common.core.mq.DeviceReportBo;

/**
 * @author bill
 */
public interface IEmqxMessageProducer {

    void sendEmqxMessage(String topicName, DeviceReportBo deviceReportBo);

}
